package com.winit.schedule.core.repository;

import java.util.List;

import com.winit.schedule.core.repository.entity.LogEntity;
import com.winit.schedule.core.repository.entity.Page;

/**
 * 日志持久化
 * 
 * @author jianke.zhang 2015-3-30 上午9:40:47
 * @since 1.0
 */
public interface LoggerRepository {

    void saveLogger(LogEntity entity);

    void saveLogger(List<LogEntity> entitys);

    List<LogEntity> queryLogByJobId(String jobId);

    Page queryTaskTrackerLog(String taskTrackerUuid, long startTime, long endTime, int page, int rows);

    Page queryJobLog(String jobId, long startTime, long endTime, int page, int rows);

    Page queryTaskTrackerDisconnectLog(String ip, long startTime, long endTime, int page, int rows);

    Page queryTaskExeFailureLog(String jobId, String taskId, long startTime, long endTime, int page, int rows);
    
    Page queryTaskLog(String jobId, String taskId, long startDate, long endDate, int page, int rows);
}
